package com.ahcloud.edas.gatewaylog.biz.infrastructure.log.client;

import com.ahcloud.edas.gatewaylog.biz.domain.log.dto.GatewayRequestLogDTO;

import java.util.List;

/**
 * @program: ahcloud-operatelog
 * @description:
 * @author: YuKai Fan
 * @create: 2024/5/26 20:59
 **/
public interface LogConsumeClient<L extends GatewayRequestLogDTO> extends AutoCloseable {

    /**
     * 初始化客户端
     */
    default void initClient() {

    }
    /**
     * collect logs
     * @param logs
     */
    void consume(List<L> logs) throws Exception;
}
